package org.springblade.common.mq;

import cn.hutool.core.date.DateUtil;
import cn.hutool.json.JSONUtil;
import com.aliyun.openservices.ons.api.PropertyValueConst;
import com.github.thierrysquirrel.annotation.MessageListener;
import com.github.thierrysquirrel.annotation.RocketListener;
import lombok.extern.slf4j.Slf4j;
import org.springblade.core.log.exception.ServiceException;
import org.springblade.core.tool.utils.Func;
import org.springblade.modules.admin.dto.RescueNoticeCreateDTO;
import org.springblade.modules.admin.dto.RescueRoomPersonDTO;
import org.springblade.modules.admin.service.IRescueNoticeService;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import javax.annotation.Resource;

/**
 * @Description
 * @Author ysq
 * @Date 2023/6/19
 **/
@Slf4j
//@RocketListener(groupID = "GID_RESCUE_TEST",messageModel = PropertyValueConst.BROADCASTING)
public class MessageReceive {

	@Resource
	private IRescueNoticeService rescueNoticeService;

//	@MessageListener(topic = "rescue_notice_test", tag = "rescue")
	public void rescueMessage(String message) {
		log.debug("救援通知，接收时间:[{}],接受内容:[{}]", DateUtil.now(), message);
	}

}
